/*
 * Copyright 2007 - The JDPF Project Team (http://www.jdpf.org) 
 * 
 * Licensed under the Apache License, Version 2.0 (the "License"); 
 * you may not use this file except in compliance with the License. 
 * You may obtain a copy of the License at 
 * 
 * http://www.apache.org/licenses/LICENSE-2.0 
 * 
 * Unless required by applicable law or agreed to in writing, software 
 * distributed under the License is distributed on an "AS IS" BASIS, 
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 * See the License for the specific language governing permissions and 
 * limitations under the License. 
 */
package org.jdpf.core.netloader;

import java.util.Iterator;
import java.util.List;

import org.jdpf.core.kernel.elements.ITransition;
import org.jdpf.core.kernel.plugins.IPluginsFrameworkConstants;
import org.jdpf.core.plugins.blocks.AbstractTransitionPlugin;

public class PipeValidator {
    	
    	private int count;

	public PipeValidator() {
		count = 0;
	}

	public void updateCount(List<ITransition> list) {
		Iterator ii=list.iterator();
		while(ii.hasNext()){
			AbstractTransitionPlugin plugin=(AbstractTransitionPlugin) ii.next();
			String cat = plugin.getCategory();
			if (cat.equalsIgnoreCase(IPluginsFrameworkConstants.GENERATOR)) {
				count++;
			} else if (cat.equalsIgnoreCase(IPluginsFrameworkConstants.SERIALIZER)) {
				count--;
			} else if (cat.equalsIgnoreCase(IPluginsFrameworkConstants.SPLIT)) {
				count += plugin.getOutputArcs().size() - 1;
			} else if (cat.equalsIgnoreCase(IPluginsFrameworkConstants.JOIN)) {
				count =count-(plugin.getInputArcs().size() - 1);
			}
		}
	}

	public boolean isValid() {
		return count == 0;
	}

}
